package com.swak.reactivex.transport.funcs;

import java.util.concurrent.CompletionStage;

import com.swak.exception.RemotingException;
import com.swak.reactivex.transport.ExchangeChannel;

@FunctionalInterface
public interface ExchangeReplyHandler {

	CompletionStage<Object> reply(ExchangeChannel channel, Object message) throws RemotingException;
}
